package org.budo.warehouse.logic.consumer;

import org.budo.warehouse.logic.api.AbstractDataConsumer;
import org.budo.warehouse.logic.api.DataMessage;
import org.budo.warehouse.logic.util.DataMessageUtil;

import lombok.extern.slf4j.Slf4j;

/**
 * @author lmw
 */
@Slf4j(topic = "consumer.log")
public class LogDataConsumer extends AbstractDataConsumer {
    @Override
    public void consume(DataMessage dataMessage) {
        log.info("#16 pipeline=" + this.getPipeline().getId() + ", dataMessage=" + DataMessageUtil.toSimpleString(dataMessage));
    }
}